package dmp.tags

import org.apache.spark.sql.Row
import org.apache.spark.sql.catalyst.util.StringUtils

/**
  * author:CN.CDG
  * Date:2019/2/16
  * Time:10:46
  * 广告位和广告类型标签
  **/
object AdTags extends Tags {
  override def mkTags(args: Any*): List[(String, Int)] = {
    //创建一个用于返回的List集合
    var list=List[(String,Int)]()

    //
    val row=args(0).asInstanceOf[Row]

    val adType = row.getAs[Int]("adspacetype")
    if (adType>9){
      list:+=("LC"+adType,1)
    }else if(adType>0 && adType<=9){
      list:+=("LC0"+adType,1)
    }
    //获取广告类型名称
    val adSpName = row.getAs[String]("adspacetypename")
    if(!"".equals(adSpName)){
      list:+=("LN"+adSpName,1)
    }
    //获取渠道id
        val adplatform = row.getAs[Int]("adplatformproviderid")
    list:+=("CN"+adplatform,1)
    list
  }
}
